package com.im.service.websocket.message;

import com.im.service.infra.entity.ChatHistory;
import com.im.service.websocket.message.dto.SentMessage;
import com.im.service.websocket.message.enums.MessageType;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface MessageProcessor {
    Mono<Void> process(String senderId, SentMessage sentMessage);

    MessageType messageType();
}
